package com.atguigu.flink.chapter05.source;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author lizhenchao@atguigu.cn
 * @Date 2021/9/14 11:12
 */
public class Flink02_Source_File {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        // 传递文件路径: 可以是相对路径也可以是绝对路径
       /* env
            .readTextFile("hdfs://hadoop162:8020/words.txt")
            .print();
    */
       // 相对路径: 相对谁?
        // idea: 相对于 project的根目录
        // standalone: 相对用户的家目录
        // yarn: 相对于用户的家目录
        env
            .readTextFile("input/words.txt")
            .print();
        env.execute("Flink02_Source_File");
    }
}
